package com.myself.config;

import org.springframework.amqp.core.DirectExchange;
import org.springframework.amqp.core.Queue;
import org.springframework.amqp.core.TopicExchange;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

/**
 * @author W.S.
 * @version v4.0.0
 * @description
 * @date Created in 2018/8/23 11:16
 */
@Configuration
public class RabbitExchangeConfig {

    /**
     * 点对点交换机
     */
    public static final String DIRECT_EXCHANGE = "direct.exchange";

    /**
     * 默认的 点对点的交换机
     * @return
     */
   /* @Bean
    public DirectExchange testDirectExachange(){
        return new DirectExchange(DIRECT_EXCHANGE);
    }*/

    /**
     * topic 交换机
     * @return
     */
    /*@Bean
    public TopicExchange topicExchange(){
        return  new TopicExchange("topic.exchange");
    }*/

}
